package com.alan.datasync.service;

/**
 * @Author: li_jl
 * @Description: 消息处理器
 * @Date: Created in 2020/6/8 4:50 下午
 */
public interface IOggKafkaMessageService {
    /**
     * kafka消息处理
     *
     * @param payload
     */
    void dealMessage(String payload);
}